d2f148940680b0112fd70681352ad01b8da58b1b,src/test/java/reactor/core/publisher/FluxPublishOnTest.java,FluxPublishOnTest,crossRangeHidden,#,618

Before Change



	@Test
	public void crossRangeHidden() {
		AssertSubscriber<Integer> ts = AssertSubscriber.create();

		int count = 1000000;

		Flux.range(1, count)
		    .hide()
		    .flatMap(v -> Flux.range(v, 2)
		                      .hide(), false, 128, 1)
		    .hide()
		    .publishOn(Schedulers.fromExecutorService(exec))
		    .subscribe(ts);

		if (!ts.await(Duration.ofSeconds(5))
		       .isTerminated()) {
			ts.cancel();
		}

		ts.assertValueCount(count * 2)

After Change


	public void crossRangeHidden() {
		int count = 1000000;

		StepVerifier.create(Flux.range(1, count)
		                        .hide()
		                        .flatMap(v -> Flux.range(v, 2)
		                                          .hide(), false, 128, 1)
		                        .hide()
		                        .publishOn(Schedulers.fromExecutorService(exec)))
		            .expectNextCount(2 * count)
		            .verifyComplete();
	}

	@Test